Apache ActiveMQ ™ -- Advisory Support in ActiveMQ 3

Site > Old Links > Previous Versions > Advisory Support in ActiveMQ 3

For users of Apache ActiveMQ 4.0 or later please see Advisory Message. In previous 3.x versions the following is supported:-

The destination string constants are available in ActiveMQDestination

<![CDATA[ ActiveMQDestination.CONSUMER_ADVISORY_PREFIX ActiveMQDestination.PRODUCER_ADVISORY_PREFIX ActiveMQDestination.CONNECTION_ADVISORY_PREFIX ActiveMQDestination.TEMP_DESTINATION_ADVISORY_PREFIX ]]>

A subscription to each of the destination returns an ObjectMessage with a specific object: ConsumerInfo, ProducerInfo,ConnectionInfo, TempDestinationAdvisoryEvent.

For example:

<![CDATA[ ... String advisoryName = ActiveMQDestination.PRODUCER_ADVISORY_PREFIX + destination.getPhysicalName(); Destination advisoryDestination = ActiveMQDestination.createDestination(destination.getDestinationType(), advisoryName); MessageConsumer consumer = session.createConsumer(advisoryDestination); consumer.setMessageListener(this); .... public void onMessage(Message msg){ if (msg instanceof ObjectMessage){ try { ProducerInfo info = (ProducerInfo)((ObjectMessage)msg).getObject(); } catch (JMSException e) { log.error("Failed to process message: " + msg); } } } ]]>

Overview

Sub Projects

Community

Features

Connectivity

Using ActiveMQ 5

Using ActiveMQ 4

Tools

External Tools

Support

Developers

Tests

Project Reports

results matching ""

    No results matching ""